package cn.com.bluemoon.bd.flink.udf;

import cn.com.bluemoon.bd.utils.DateUtils;
import org.apache.flink.table.functions.ScalarFunction;

/**
 * @author 刘天能
 * @createAt 2020-08-10 17:24
 * @description 日期增加UDF，增加天数（interval）
 */
public class DateAdd extends ScalarFunction {
    public String eval(String date, String dateFormat, int interval) {
        if (null == date) return null;
        return DateUtils.getAddDate(date, dateFormat, interval);
    }
}
